//package ds_recommended
//
//import org.apache.spark.sql.SparkSession
//import org.apache.spark.sql.functions.col
//
//import java.util.Properties
//
//object user_buy_info_clean {
//  def main(args: Array[String]): Unit = {
//
//    /*
//        由于手机类型商品信息被删除，所以订单表也必须删除购买了手机的订单
//     */
//
//    val spark=SparkSession.builder()
//      .master("local[*]")
//      .appName("处理订单表")
//      .getOrCreate()
//
//    val connect=new Properties()
//    connect.setProperty("user","root")
//    connect.setProperty("password","123456")
//    connect.setProperty("driver","com.mysql.jdbc.Driver")
//
//    spark.read
//      .jdbc("jdbc:mysql://192.168.67.193:3307/source?useSSL=false","order_info",connect)
//      .withColumn("product_id",col("product_id").cast("int"))
//      .createOrReplaceTempView("data")
//
//    val data=spark.sql(
//      """
//        |select
//        |*
//        |from data as a
//        |where a.product_id <100 or a.product_id > 119
//        |""".stripMargin)
//
//    data.show()
//
//    data.write.mode("overwrite")
//      .option("batchsize", "100000")  // 每次插入 1000 条记录
//      .option("isolationLevel", "NONE")
//      .option("autocommit", "false")
//      .jdbc("jdbc:mysql://192.168.67.193:3307/ods?useSSL=false","order_info",connect)
//
//
//
//    spark.close()
//  }
//
//}
